آموزش میکروسرویس‌های کافکا با Spring Boot، Docker، Kubernetes و AI [ویدئویی] - آخرین آپدیت

سرفصل ها و درس ها

شروع کار با دوره Getting Started with Course

• معرفی دوره و اهداف Course Introduction & Objectives

• پیش‌نیازها Pre-Requisites

شروع کار با کافکا Getting Started with Kafka

• مقدمه‌ای بر کافکا Introduction to Kafka

• اصطلاحات اصلی کافکا Kafka Core Terminologies

• APIهای کلاینت کافکا Kafka Client APIs

نصب داکر Docker Installation

• نصب داکر Installing Docker

درک اجزا و ساختار داخلی کافکا Understanding Kafka Components and Its Internals

• تاپیک‌ها و پارتیشن‌های کافکا: تئوری Kafka Topics and Partitions - Theory

• راه‌اندازی بروکر کافکا در محیط محلی: Controller و KRaft Set Up a Kafka Broker in Local: Controller, KRaft (Consensus Protocol)

• ساخت تاپیک، تولید و مصرف پیام‌ها با استفاده از CLI Create Topic, Produce and Consume Messages Using the CLI

• تولید و مصرف پیام‌ها با استفاده از Key Produce and Consume Messages with Key

• API تولیدکننده: در پشت صحنه چگونه کار می‌کند؟ Producer API - How Does It Work Under the Hood?

• آفست‌های مصرف‌کننده (Consumer Offsets) Consumer Offsets

• گروه‌های مصرف‌کننده (Consumer Groups) Consumer Groups

• API مصرف‌کننده: در پشت صحنه چگونه کار می‌کند؟ Consumer API - How Does It Work Under the Hood?

• Commit Log و سیاست‌های نگهداری (Retention Policy) Commit Log and Retention Policy

• سیستم‌های توزیع شده چیستند؟ What Are Distributed Systems?

• کافکا به عنوان یک سیستم استریم توزیع شده Kafka as a Distributed Streaming System

• راه‌اندازی کلاستر کافکا محلی با 3 بروکر Setting Up a Kafka Cluster in Local with 3 Kafka Brokers

• انتخاب لیدر (Leader Election) در عمل Leader Election in Action

• بررسی ISR و min.insync.replicas در عمل ISR and min.insync.replicas in Action

• کافکا چگونه پارتیشن‌ها را بین بروکرها توزیع می‌کند؟ How Kafka Distributes Partitions Across Brokers?

مروری بر اپلیکیشن Application Overview

• مروری بر اپلیکیشن: سرویس موجودی کتابخانه Overview of the Application - Library Inventory Service

توسعه مبتنی بر AI: کدنویسی Vibe و مهندسی Agentic AI-Driven Development - Vibe Coding, Agentic Engineering

• کدنویسی با AI چگونه تغییر کرده است؟ How Coding Has Changed with AI?

• کدنویسی Vibe در مقابل مهندسی Agentic Vibe Coding vs Agentic Engineering

راه‌اندازی محلی: IDE Local Set Up: IDE

• دانلود IDE اینتلی‌ج (Intellij) Intellij IDE Download

ساخت میکروسرویس Kafka Producer برای رویدادهای کتابخانه Build LibraryEvents Kafka Producer MicroService

• راه‌اندازی پروژه پایه تولیدکننده رویدادهای کتابخانه Set Up the Library Events Producer Base Project

• دستیار کدنویسی AI: راه‌اندازی Copilot AI Coding Assistant: Copilot Set Up

• توسعه مبتنی بر مشخصات: ایجاد سند PRD برای سرویس ما Spec Driven Development: Create the PRD Document for Our Service

• ایجاد سند PRD برای تولیدکننده LibraryEvents Create a PRD Document for LibraryEvents Producer

• برنامه پیاده‌سازی بر اساس مشخصات Implementation Plan from the Spec

• ساخت زیربنای پروژه Build the Project Foundation

• ساخت دامنه (Domain) رویداد کتابخانه Build the Library Event Domain

• ایجاد نقطه انتهایی POST: "/libraryevents" Create the POST Endpoint: "/libraryevents"

• مقدمه‌ای بر KafkaTemplate Introduction to KafkaTemplate

• استفاده عملی از KafkaTemplate برای ارسال رویدادها KafkaTemplate in Action to Send Events

• استفاده از Spring Docker Compose برای کلاستر محلی کافکا Using Spring Docker Compose for Local Kafka Cluster

• بررسی ساختار داخلی KafkaTemplate KafkaTemplate Under the Hood

• بررسی عمیق دسته‌بندی (Batching) و بافرینگ Batching & Buffering Deep Dive

• AutoConfiguration در KafkaTemplate چگونه کار می‌کند؟ How the KafkaTemplate AutoConfiguration Works?

• مقایسه StringSerializer و JsonSerializer StringSerializer vs JsonSerializer

• افزودن RestControllerAdvice برای مدیریت خطاهای سفارشی Add RestControllerAdvice for Custom Error Handling

• ارسال همزمان (Synchronous) رویدادها با KafkaTemplate Synchronous Sending Events Using KafkaTemplate

• مدل Threading در KafkaTemplate: بررسی داخلی KafkaTemplate Threading Model - Under the Hood

• ساخت نقطه انتهایی PUT برای ارسال پیام‌ها با Key Build a PUT Endpoint to Send Messages with the Key

• مدیریت استثناها برای شکار تمامی خطاها Exception Handling to Catch All the Exceptions

• پروفایل‌های Spring: مدیریت پیکربندی‌های مختلف بر اساس محیط Spring Profiles: Maintain Different Kafka Producer Configs by Environment

تست واحد و یکپارچگی: API تولیدکننده رویدادهای کتابخانه با کمک AI Unit and Integration Testing - Library Events Producer API - AI Assisted

• مقدمه‌ای بر تست‌های واحد و یکپارچگی Introduction to Unit and Integration Testing

• تست واحد نقطه انتهایی POST با استفاده از mockMvc UnitTesting POST Endpoint Using mockMvc

• تست واحد نقطه انتهایی PUT با استفاده از mockMvc UnitTesting PUT Endpoint Using mockMvc

• تست یکپارچگی نقطه انتهایی POST Integration Testing POST Endpoint

• تست یکپارچگی نقطه انتهایی PUT Integration Testing PUT Endpoint

• تست واحد LibraryEventProducer با KafkaTemplate Unit Testing LibraryEventProducer with KafkaTemplate

مستندسازی REST APIها با Swagger / OpenAPI 3 Documenting REST APIs with Swagger / OpenAPI 3

• چرا OpenAPI برای APIهای مدرن اهمیت دارد؟ Why OpenAPI Matters for Modern APIs?

• OpenAPI در عمل: افزودن Swagger برای تولیدکننده LibraryEvents OpenAPI in Action: Add Swagger for LibraryEvents Producer

استفاده از Agents.MD و Skill.md برای Copilot جهت خروجی کد مرتبط Agents.MD and Skill.md for Copilot - For Relevant Code Output

• Agents.MD چیست و چگونه ساخته می‌شود؟ What Is Agents.MD and How to Create Them?

• «مهارت» (Skill) در یک Agent کدنویسی چیست؟ What Is a "Skill" in a Coding Agent?

• ساخت «مهارت تست» (Testing Skill) Create "Testing Skill"

• ساخت «مهارت کنترلر» (Controller Skill) Create "Controller Skill"

ساخت میکروسرویس Kafka Consumer برای رویدادهای کتابخانه Build LibraryEvents Kafka Consumer MicroService

• مصرف‌کننده رویدادهای کتابخانه: بازبینی معماری و سند PRD Library Events Consumer: Architecture Revisit and PRD Document

• راه‌اندازی پروژه پایه مصرف‌کننده رویدادهای کتابخانه Set Up the Library Events Consumer Base Project

• برنامه پیاده‌سازی برای سرویس مصرف‌کننده رویدادهای کتابخانه Implementation Plan for Library-Events-Consumer Service

• ساخت مصرف‌کننده کافکا با استفاده از @KafkaListener Build the Kafka Consumer Using @KafkaListener

• تست LibraryEventConsumer: پول کردن، خواندن و لاگ کردن رویداد Testing the LibraryEventConsumer - Poll, Read, and Log LibraryEvent

• دی‌سریالیزه کردن JSON خام به LibraryEventDto Deserialize the Raw JSON into LibraryEventDto

• مقایسه StringDeserializer و JsonDeserializer StringDeserializer vs JsonDeserializer

• ساختار داخلی Spring Kafka Consumer و AutoConfiguration How Spring Kafka Consumer Works Under the Hood + Spring Kafka AutoConfiguration

• AutoConfiguration در Spring Kafka Consumer چگونه کار می‌کند؟ Spring Kafka Consumer AutoConfiguration - How Does It Work?

گروه‌های مصرف‌کننده و مدیریت Offset مصرف‌کننده Consumer Groups and Consumer Offset Management

• گروه‌های مصرف‌کننده و Rebalance: تمرین عملی Consumer Groups and Rebalance - Hands On

• مدیریت پیش‌فرض Offset در Spring Kafka: تمرین عملی Default Consumer Offset Management in Spring Kafka - Hands On

• مدیریت دستی Offset مصرف‌کننده: تمرین عملی Manual Consumer Offset Management - Hands On

• مصرف‌کنندگان همزمان (Concurrent Consumers): تمرین عملی Concurrent Consumers - Hands On

ذخیره رویدادهای کتابخانه در پایگاه داده Saving the Library Events in DB

• راه‌اندازی دیتابیس Postgres در اپلیکیشن مصرف‌کننده Set Up Postgres DB into the LibraryEvents Consumer App

• ادغام Flyway برای مدیریت دیتابیس اپلیکیشن Integrate Flyway for Managing DB for the App

• ساخت کلاس‌های Entity برای LibraryEvent و Book Create Entity Classes Representing the LibraryEvent and Book Entity

• ساخت کلاس Repository برای عملیات JPA Create Repository Class for JPA Operations

• منطق تجاری (Business Logic) در سرویس رویداد کتابخانه Business Logic in Library Event Service

• تست جریان کامل: Producer + Consumer + DB Test the Flow End to End: Producer + Consumer + DB

تست یکپارچگی با استفاده از Embedded Kafka برای مصرف‌کننده Integration Testing Using Embedded Kafka - Kafka Consumer

• تست یکپارچگی برای مصرف‌کننده LibraryEvent Integration Test for the LibraryEvent Consumer

استفاده از Agents.MD برای مصرف‌کننده رویدادهای کتابخانه Agents.MD for LibraryEvents Consumer

• استفاده از Agents.MD برای مصرف‌کننده LibraryEvents Agents.MD for LibraryEvents Consumer

ساخت نقاط انتهایی CRUD برای نمایش داده‌های کتاب و رویدادها Build CRUD Endpoints to Expose LibraryEvent and Book Data

• نقطه انتهایی CRUD برای مدیریت داده‌های کتاب CRUD Endpoint to Manage the Book Data

• فعال‌سازی Swagger Spec برای مصرف‌کننده رویدادهای کتابخانه Enable Swagger Spec for the Library Events Consumer

• نقطه انتهایی GET برای LibraryEvents GET Endpoint for LibraryEvents

تولیدکننده کافکا: مدیریت استثناها و خطاها Kafka Producer: Exception & Error Handling

• بررسی acks و min.insync.replicas acks and min.insync.replicas

• بررسی Retry و RetryBackOff Retry and RetryBackOff

• تولیدکننده Idempotent Idempotent Producer

• بررسی max.in.flight.requests.per.connection max.in.flight.requests.per.connection

• Timeouts در تولیدکننده Producer Timeouts

• پیکربندی پیشنهادی برای تولیدکننده قابل اطمینان Recommended Reliable Producer Configuration

• مدیریت منطق خطا در LibraryEventsProducer: تولیدکننده Async و Sync Handling the Error Logic in LibraryEventsProducer: Async and Sync Producer

مصرف‌کننده کافکا: مدیریت استثناها و خطاها (تلاش مجدد و بازیابی) Kafka Consumer: Exception & Error Handling (Retry and Recovery)

• برنامه‌ریزی برای مدیریت خطا در مصرف‌کننده کافکا Plan for Error Handling in Kafka Consumer

• بررسی رفتار فعلی مصرف‌کننده Exploring Current Consumer Behavior

• ساختار داخلی مدیریت خطای Spring Kafka Spring Kafka Error Handling - Under the Hood

• تلاش مجدد: پیکربندی DefaultErrorHandler با Exponential Backoff Retry: Configuring DefaultErrorHandler Using Exponential Backoff

• تلاش مجدد: فعال‌سازی RetryListener برای واکنش به تلاش‌ها Retry: Enable "RetryListener" to Act on Retry Attempts

• بررسی استثناهای Retryable و Non-Retryable در عمل Retryable & Non-Retryable Exceptions in Action

• بازیابی: مروری بر استراتژی‌های مختلف Recovery Recovery: Overview of Different Recovery Strategies

• بازیابی: ارسال رکوردهای خطا به تاپیک DeadLetter در عمل Recovery: Publish Exception Records to DeadLetter Topic in Action

• بازیابی: لاگ کردن، نادیده گرفتن و نوشتن رکوردهای خطا در DB Recovery: Log and Skip + Write Failure Records to a DB

• بازیابی: رویکرد ترکیبی (ارسال و ذخیره رکوردهای خطا) Recovery: Publish and Save the Failure Records (Hybrid Approach)

• جمع‌بندی: پیکربندی کامل Retry + Recovery Recap: Complete Retry + Recovery Configuration

• به‌روزرسانی تست‌های یکپارچگی با Retry و Recovery Update the Integration Tests with Retry & Recovery

پیکربندی‌های زمانی مصرف‌کننده کافکا Kafka Consumer Timing Configurations

• مصرف‌کننده کافکا: پیکربندی‌های زمانی سمت بروکر Kafka Consumer: Broker Side Time Configurations

• مصرف‌کننده کافکا: پیکربندی‌های زمانی Fetch Kafka Consumer: Fetch Time Configurations

• مصرف‌کننده کافکا: پیکربندی‌های زمانی اتصال (Connection) Kafka Consumer: Connection Time Configurations

تراکنش‌های کافکا: معناشناسی Exactly Once Kafka Transactions: Exactly Once Semantics

• تراکنش کافکا و معناشناسی Exactly Once چیست؟ What Is Kafka Transaction and Exactly Once Semantics?

• رویکرد اول: دستیابی به Exactly Once با استفاده از @Transactional Approach 1: Achieve Exactly Once Semantics Using @Transactional

• ارسال چندین پیام به عنوان یک تراکنش Publish Multiple Messages as a Transaction

• رویکرد دوم: تراکنش با استفاده از KafkaTemplate.executeInTransaction() Approach 2: Transaction Using KafkaTemplate.executeInTransaction()

• به‌روزرسانی تست‌های یکپارچگی با تراکنش‌ها [تولیدکننده رویدادهای کتابخانه] Update Integration Tests With Transactions [Library Events Producer]

• تراکنش‌ها در مصرف‌کننده Transactions in Consumer

بررسی سلامت و مانیتورینگ کافکا با SpringBoot Actuator Kafka Health Checks and Monitoring Using SpringBoot Actuator

• مقدمه‌ای بر SpringBoot Actuator Introduction to SpringBoot Actuator

• فعال‌سازی Health Check در تولیدکننده رویدادهای کتابخانه Enabling Health Check in Library Events Producer

• شاخص سلامت Readiness کافکا در عمل Kafka Readiness Health Indicator in Action

• فعال‌سازی HealthCheck و Kafka Readiness در مصرف‌کننده رویدادهای کتابخانه Enabling HealthCheck and Kafka Readiness in Library Events Consumer

بسته‌بندی اپلیکیشن‌ها به صورت Executable Jar Package the Apps as Executable Jar

• تولیدکننده LibraryEvents به عنوان Executable Jar: ساخت و اجرا LibraryEvents Producer as Executable Jar - Build and Launch the App

• ارسال متغیرهای محیطی (Environment Variables) Passing the Environment Variables

• مصرف‌کننده LibraryEvents به عنوان Executable Jar: ساخت و اجرا LibraryEvents Consumer as Executable Jar - Build and Launch the App

مقدمه‌ای بر کانتینرها: ساخت و اجرای کانتینرها با Docker Introduction to Containers: Build and Run Containers Using Docker

• کانتینرها: چرا و چیست؟ Containers: Why and What?

• مقدمه‌ای بر داکر (Docker) Introduction to Docker

• ساخت Image داکر برای تولیدکننده رویداد کتابخانه Create the Docker Image for Library Event Producer

• اجرای Image داکر برای تولیدکننده رویداد کتابخانه Run Docker Image for Library Event Producer

• اجرای همان Image در محیط‌های مختلف Running the Same Image with Different Environments

• انتشار Image داکر در DockerHub Publish the Docker Image to DockerHub

• ساخت و اجرای Image داکر برای مصرف‌کننده رویدادهای کتابخانه Build and Run the Docker Image for the Library Events Consumer

اجرای اپلیکیشن‌های Spring Boot روی Kubernetes Running Spring Boot Apps on Kubernetes

• چرا کوبرنتیز؟ مشکل داکر به تنهایی Why Kubernetes? - The Problem with Docker Alone

• کوبرنتیز (Kubernetes) چیست؟ What Is Kubernetes?

• معماری کوبرنتیز Kubernetes Architecture

• راه‌اندازی محلی کوبرنتیز با Minikube Setting Up Kubernetes Locally - Minikube

• راه‌اندازی kubectl: ابزار CLI برای کوبرنتیز Setting Up kubectl - CLI for Kubernetes

• Deploymentها و Podها در کوبرنتیز Deployment and Pods in Kubernetes

• نمایان کردن نقاط انتهایی اپلیکیشن با Kubernetes Service Exposing the App Endpoints Using Kubernetes Service

• نمایان کردن نقاط انتهایی با Kubernetes Port Forward Exposing the App Endpoints Using Kubernetes Port Forward

• نمایان کردن نقاط انتهایی با Kubernetes Ingress Exposing the App Endpoints Using Kubernetes Ingress

• مقیاس‌بندی به چندین Replica: چرا و چگونه؟ Scaling to Multiple Replicas - Why and How to Do It?

• خارج کردن پیکربندی‌ها با استفاده از ConfigMap Externalize the Configs Using ConfigMap

• بررسی Liveliness و Readiness در Deploymentهای کوبرنتیز Liveliness and Readiness Checks with Kubernetes Deployments

• راه‌اندازی کوبرنتیز برای مصرف‌کننده رویدادهای کتابخانه Library Events Consumer - Kubernetes Setup

• خارج کردن پیکربندی‌ها با استفاده از Kubernetes Secrets Externalize the Configs Using Kubernetes Secrets

• خارج کردن Secretها با استفاده از Volume Mount Externalize Secrets Using Volume Mount